from airflow.models.idata_task import Task
from airflow.utils.session import create_session
from airflow.patsnap.service import task_service

with create_session() as session:
    task = session.query(Task).filter(Task.id == 3).first()
    task_service.run_by_scheduler(task)

